| @@ -109,7 +109,7 @@ module Agents | ||
| 109 | 109 | def receive(incoming_events) | 
| 110 | 110 | mqtt_client.connect do |c| | 
| 111 | 111 | incoming_events.each do |event| | 
| 112 | - c.publish(interpolated(event)['topic'], event) | |
| 112 | + c.publish(interpolated(event)['topic'], event.payload) | |
| 113 | 113 | end | 
| 114 | 114 | end | 
| 115 | 115 | end |